from celery import Celery

"""
    必须先导入工程的配置文件
    创建celery实例
    让celery加载broker
    celery实例对象自动检测
"""
# 进行Celery允许配置
# 为celery使用django配置文件进行设置
import os
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'ten_times.settings'

# 创建celery对象
# 参数main 其实就是给celery设置一个名字,这个名字唯一就可以了
# 设置脚本名,推荐使用 文件路径

app = Celery(main='celery_tasks')

# 加载配置文件,让celery加载broker
app.config_from_object('celery_tasks.config')

# 自动加载任务
# 参数是列表,需要填写 任务的包路径
app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.mail'])

# worker
# celery -A celery实例对象所在的文件 worker -l info
# celery -A celery_tasks.main worker -l info